package com.wxg.config.rocketmq;

import com.wxg.domain.MqConstant;
import org.apache.rocketmq.client.producer.MessageQueueSelector;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.common.message.MessageQueue;

import java.util.List;

/**
 * @author void
 * @date 2020/6/1 14:16
 * @desc
 */
public class IRocketMqSelector implements MessageQueueSelector {
    @Override
    public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
        return mqs.get(MqConstant.env-1);
    }
}
